package com.hfzy.ihk.web.callhistoryold.utils.kafka;

import kafka.producer.KeyedMessage;

import java.util.concurrent.LinkedBlockingQueue;

/**
 * Created by Administrator on 2017/3/20.
 */
public class CacheQueue {
    private static LinkedBlockingQueue<KeyedMessage<String, String>> queu = new LinkedBlockingQueue<KeyedMessage<String, String>>();

    public static LinkedBlockingQueue<KeyedMessage<String, String>> getQueu() {
        return queu;
    }

    public static void put(KeyedMessage<String, String> keyedMessage) throws InterruptedException {
        queu.put(keyedMessage);
    }

}
